const WebSocket = require('ws')
const read_wss = new WebSocket.Server({
    port: 9010
})
// 模拟的数据1
const string = ['AAAAA', 'BBBBB', 'CCCCC', 'DDDDD', 'FFFFF', 'GGGGG']
module.exports.listener = () => {
    // 图表监听
    read_wss.on('connection', (ws, req) => {
        console.log('WebSocket服务：9010已成功连接')
        ws.on('message', msg => {
            console.log('Messag', msg)
            // let i = 0
            setInterval(() => {
                // console.log('客户端发送给服务器端', msg.toString('utf8'))
                // if (i === string.length) {
                //     i = 0
                // }
                ws.send(JSON.stringify(string[Math.floor(Math.random() * string.length)]))
                // i++
            }, 1000)
        })

        // 监听要关闭连接的函数
        ws.on('close', function close() {
            ws.close();
            // 这里面关闭的逻辑
            console.log('WebSocket连接已关闭')
        })
    }) 
}